# -*- coding: utf-8 -*-
from datetime import timedelta
from utils.operators.bash import BashOperator
from jms_hi.dwd.data_plat.dwd_indicator_onlinezation import jms_dwd__dwd_indicator_onlinezation
doris_jms_dwd__dwd_indicator_onlinezation = BashOperator(
    task_id='doris_jms_dwd__dwd_indicator_onlinezation',
    execution_timeout=timedelta(hours=2),
    retries=2,
    email=['yl_etl@yl-scm.com','yl_bigdata@yl-scm.com'],
    bash_command="jms_hi/doris/data_plat/doris_dwd_indicator_onlinezation/execute.sh",
    pool='broker_load_pool',
    pool_slots=8,
)

doris_jms_dwd__dwd_indicator_onlinezation << jms_dwd__dwd_indicator_onlinezation